package com.nucarf.bi.digtalize.config;

import com.nucarf.bi.digtalize.util.PropertyUtil;
import org.apache.flink.util.PropertiesUtil;

import java.util.Properties;

public class KafkaConfig {

    public static Properties getKafkaConfig() {
        Properties prop = new Properties();
        prop.put("bootstrap.servers", PropertyUtil.getPropertyValue("kafka.bootstrap.servers"));
        prop.put("acks", PropertyUtil.getPropertyValue("kafka.acks"));
        prop.put("retries", PropertyUtil.getPropertyValue("kafka.retries"));
        prop.put("transaction.timeout.ms", 1000 * 60 * 5 );
        return prop;
    }

}
